package com.shujia.spark.opt

import com.esotericsoftware.kryo.Kryo
import com.shujia.spark.opt.Demo7Kyyo.Student
import org.apache.spark.serializer.KryoRegistrator

class Demo8KryoRegister extends KryoRegistrator {
  override def registerClasses(kryo: Kryo): Unit = {
    /**
     * 在这个方法中将需要使用kryo进行序列化的类做一个注册
     *
     */
    kryo.register(classOf[Student])
    kryo.register(classOf[String])
    kryo.register(classOf[Int])
  }
}
